a5d2255fce445946b61e8b21ac1f054d4cdafcb3,src/test/java/reactor/core/publisher/FluxPublishOnTest.java,FluxPublishOnTest,normalSyncFusedBackpressured,#,163
Before Change
@Test
public void normalSyncFusedBackpressured() throws Exception {
AssertSubscriber<Integer> ts = AssertSubscriber.create(0);
Flux.range(1, 1_000_000)
.publishOn(Schedulers.fromExecutorService(exec))
.subscribe(ts);
ts.assertNoValues()
.assertNoError()
.assertNotComplete();
ts.request(500_000);
Thread.sleep(500);
ts.assertValueCount(500_000)
.assertNoError()
.assertNotComplete();
ts.request(500_000);
ts.await(Duration.ofSeconds(10));
ts.assertTerminated();
ts.assertValueCount(1_000_000)
After Change
@Test
public void normalSyncFusedBackpressured() throws Exception {
StepVerifier.create(Flux.range(1, 1_000_000)
.publishOn(Schedulers.fromExecutorService(exec)), 0)
.thenRequest(500_000)
.expectNextCount(500_000)
.thenRequest(500_000)
.expectNextCount(500_000)
.verifyComplete();
}
@Test